package com.doit.day01;

import redis.clients.jedis.Jedis;

import java.util.Random;
import java.util.UUID;

//把生产者生产出来的任务放到缓冲区里面
public class ConsumerDemo {
    public static void main(String[] args) throws InterruptedException {
        Jedis jedis = new Jedis("linux01", 6379);

        Random random = new Random();

        while (true){
            //拿出来了，并且放回到了缓冲区里面
            jedis.rpoplpush("producer","tempArea");

            //拿着缓冲区里面的任务，去消费
            String task_id = jedis.rpop("tempArea");
            System.out.println("现在正在消费==》"+task_id);

            int i = random.nextInt(100);
            //如果随机数能够被4整除，代表这个任务失败了
            if (i % 3 == 0 ){
                System.out.println("任务失败了，失败的任务是："+task_id);
                System.out.println("被放回到缓冲区去了");
                jedis.lpush("tempArea",task_id);
            }

            Thread.sleep(3000);


        }






    }
}
